package kafkaProducer





class KafkaProducer(val topic: String) extends Thread {
  val producer: KafkaProducer[String, String] = _



}

